package main

import (
	"time"
)

func main() {
	var productTopic = "topic1"
	InitKafka()
	Send("测试3", productTopic)
	time.Sleep(time.Second)

}
